package com.gitee.xhs;

import com.gitee.xhs.sampleRecod.transactionRecord.Transaction;
import org.apache.flink.api.common.eventtime.TimestampAssigner;
import org.apache.flink.api.common.eventtime.TimestampAssignerSupplier;

/**
 * @author BigHead
 * @date 2022/7/18 14:34
 * @description CustomDefaultTimestampAssignerSupplier
 */
public class CustomDefaultTimestampAssignerSupplier implements TimestampAssignerSupplier<Transaction> {

    public static final String CUSTOM_DEFAULT_TIMESTAMP_ASSIGNER_SUPPLIER = "CustomDefaultTimestampAssignerSupplier";

    @Override
    public TimestampAssigner<Transaction> createTimestampAssigner(Context context) {
        return new CustomDefaultTimestampAssigner();
    }
}
